package mq

import (
	"context"

	"code.byted.org/gopkg/logs/v2/log"
)

func NewKafkaSender() *kafkaSender {
	return &kafkaSender{}
}

type kafkaSender struct {
}

func (k *kafkaSender) SendMessage(ctx context.Context, topicName string, data string) (err error) {
	log.V1.CtxInfo(ctx, "kafka sender topic:%s,data:%s", topicName, data)
	return nil
}
